package com.lyx.rpc.proxy.api.consumer;

import com.lyx.rpc.annotation.RpcService;
import com.lyx.rpc.protocol.RpcProtocol;
import com.lyx.rpc.protocol.request.RpcRequest;
import com.lyx.rpc.proxy.api.future.RPCFuture;
import com.lyx.rpc.registry.api.RegistryService;

/**
 * @Author by lyx
 * 服务消费者接口
 */
public interface Consumer {
    RPCFuture sendRequest(RpcProtocol<RpcRequest> requestRpcProtocol, RegistryService registryService) throws Exception;
}
